package com.ayu.shortlink.settlement.common.constant;

import lombok.Data;

/**
 * RocketMQ的常量
 */
@Data
public class RocketMQConstant {
    /**
     * 立刻执行任务的主题
     */
    public final static String TOPIC_EXECUTOR_IMMEDIATELY_TASK = "short-link_rocketmq-topic_executor-immediately-task";

    /**
     * 延迟执行任务的主题
     */
    public final static String TOPIC_EXECUTOR_DELAY_TASK = "short-link_rocketmq-topic_executor-delay-task";

    /**
     * 延迟执行任务改变状态消费者组
     */
    public final static String GROUP_DELAY_EXECUTOR_TASK_STATUS_CHANGE = "short-link_rocketmq-group_delay-executor-task-status-change";

    /**
     * 关闭订单的主题
     */
    public final static String TOPIC_CLOSE_ORDER = "short-link_rocketmq-topic_close_order";

    /**
     * 关闭订单消费者组
     */
    public final static String GROUP_CLOSE_ORDER = "short-link_rocketmq-group_close_order";

}
